import fs from 'fs';
import mysql from 'mysql2/promise';

async function main() {
    // 1. 读取JSON文件
    const rawData = fs.readFileSync('./data/movies.json', 'utf-8');
    const jsdata = JSON.parse(rawData);

    // 2. 连接数据库，修改为你自己的配置
    const connection = await mysql.createConnection({
        host: 'localhost',
        user: 'root',
        password: 'root',
        database: 'movies'
    });

    //   console.log(jsdata.data.recommendList);

    // 写入短剧分类 categories表
    // try {
    //     const sql = `INSERT INTO categories (name) VALUES (?)`;
    //     await connection.execute(sql, ['短剧']);

    // } catch (err) {
    //     console.error('数据库操作失败:', err);

    // } finally {
    //     await connection.end();
    // }


    try {
        // 3. 插入数据到数据库
        // for (const user of users) {
        //     const { id, name, age } = user;

        //     // 使用REPLACE INTO避免重复主键错误，或者使用INSERT IGNORE / INSERT ... ON DUPLICATE KEY UPDATE
        //     const sql = `REPLACE INTO users (id, name, age) VALUES (?, ?, ?)`;
        //     await connection.execute(sql, [id, name, age]);

        //     console.log(`已插入/更新用户: ${name}`);
        // }
        console.log(`已插入/更新用户:`);


    } catch (err) {
        console.error('数据库操作失败:', err);
    } finally {
        await connection.end();
    }



}

main().catch(console.error);